//package org.ricks.robot.business;
//
//import org.ricks.net.transport.kcp.KcpSession;
//import org.ricks.protocol.ByteBuf;
//import org.ricks.robot.Monitor;
//import org.ricks.robot.RobotInfo;
//import org.ricks.robot.RobotManager;
//import org.ricks.robot.RobotRun;
//import proto.common.*;
//
//import java.util.concurrent.TimeUnit;
//
//import static proto.common.ChatInfo.ChatChannel.ChatRoom;
//
//public class RobotChatAction {
//
//
//    /**
//     * chat num task
//     * @param session
//     * @param sayCount
//     */
//    public static void startRobotChatAction(KcpSession session, int sayCount) {
////        for (int i = 0; i < sayCount; i++) {
////            robotChatAction(session);
////        }
//
//        robotChatAction(session);
//    }
//
//    public static void robotChatAction(KcpSession session) {
//        Monitor.addActionRequest(session, FProto.Action.Chat);
//        RobotRun.scheduledExecutorService.schedule(() -> {
//            RobotInfo robotInfo = RobotManager.get(session);
//            robotInfo.requestTimeMap.put(FProto.Action.Chat, System.currentTimeMillis());
//
//            String robotAccount = RobotManager.get(session).robotAccount;
//            long robotId = RobotManager.get(session).robotId;
//            ChatMsg chatMsg = ChatMsg.newBuilder().setMsg(robotAccount + " & " + robotId + " : say....").build();
//            MsgFromPlayer msgFromPlayer = MsgFromPlayer.newBuilder()
//                    .setFromPlayerId(1111)
//                    .setFromPlayerNickname("test")
//                    .addMsgDetailLst(chatMsg)
//                    .build();
//
//            ChatInfo chatInfo = ChatInfo.newBuilder()
//                    .setChatChannel(ChatRoom)
//                    .addMsgLst(msgFromPlayer).build();
//
//            FProto fProto = FProto.newBuilder()
//                    .setKey(FProto.Key.Player)
//                    .setAction(FProto.Action.Chat)
//                    .addChatInfo(chatInfo)
//                    .build();
//
//            byte[] data = fProto.toByteArray();
//
//            ByteBuf buf = new ByteBuf(1024);
//            buf.writeByte((byte) 0x03);
//            buf.writeBytes(data);
//            robotInfo.chatCount ++;
//            session.send(buf.toArray());
//        },1000, TimeUnit.MILLISECONDS);
//    }
//}
